package top.taooc.server;

import io.vertx.core.Vertx;

/**
 * @author songtao@guishangyi.cn
 * @date 2024年06月25日 10:19:33
 * @packageName top.taooc.taooc.rpc.easy.server
 * @className VertxHttpServer
 * @Menu
 */
public class VertxHttpServer implements HttpServer{
    /**
     * 启动服务器
     *
     * @param port
     */
    @Override
    public void doStart(int port) {
        //创建vert.x实例
        Vertx vertx = Vertx.vertx();
        io.vertx.core.http.HttpServer server = vertx.createHttpServer();
        //监听端口并处理请求
        server.requestHandler(new HttpServerHandler());

        //启动HTTP服务器并监听指定端口
        server.listen(port,result->{
            if (result.succeeded()){
                System.out.println("Server is now listening no port "+ port);
            }else {
                System.out.println("Failed to start server: "+result.cause());
            }
        });
    }
}
